package net.wanho.config;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.annotation.Configuration;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;

/**
 * Author：汤小洋
 * Date：2024-09-06 10:06
 * Description：<描述>
 */
// @Configuration
public class RabbitTemplateConfig {

    // @Resource
    // private RabbitTemplate rabbitTemplate;
    //
    // @PostConstruct
    // public void init(){
    //     // 绑定消息到达交换机时的回调函数
    //     rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
    //         if (ack){
    //             System.out.println("消息到达交换机成功........................");
    //         }else{
    //             // todo.....
    //             System.out.println("消息到达交换机失败........................" + cause);
    //         }
    //     });
    // }

}
